package com.zhangdi.mgsync.core.listener;

import java.util.Collection;

/**
 * @author zhangdi
 * @version 1.0
 * @date 2021.10.21 14:57
 */
public interface SyncListener {
    void startup(String exchange, Collection<String> collections, int seconds);
    void startup(String exchange, String collectionName, int seconds);
    void shutdown();
    void shutdown(String queue);
    String checkKey(String key);
    String addCache(String key, String val);
}
